package com.sqs.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.sqs.entity.ChatMessage;
import reactor.core.publisher.Flux;


public interface IChatMessageService extends IService<ChatMessage> {

    public Flux<String> streamChat(Long sessionId, String question);

}
